package com.retry.rabbit.lstener;


import com.retry.rabbit.config.DirectConfig;
import com.retry.rabbit.config.ErrorConfig;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

//需要被spring容器管理
@Component
/**
 * 接收方式一
 */
public class DirectListener {

    /**
     * RejectAndDontRequeueRecoverer  重试失败后，直接reject ，丢弃消息。默认就是这种方式
     * @param message
     */
    @RabbitListener(queues = DirectConfig.RETRY_QUEUE)
    public void getMessage(String message){
        System.out.println("queue01 :"+message);
        throw new RuntimeException("人为抛出异常测试重新入队");
    }



}
